package com.hjd.shop.dto.mq;

import com.hjd.shop.base.BaseEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;

import java.time.LocalDateTime;

/**
 * <p>
 * 
 * </p>
 *
 * @author 我玩亚索我会C
 * @since 2020-12-13
 */
@Data
@EqualsAndHashCode(callSuper = true)
public class MqConsumerLog extends BaseEntity {

    private static final long serialVersionUID = 1L;

    /**
     * mq消息Id
     */
    private String msgId;

    /**
     * mq组名
     */
    private String groupName;

    /**
     * mq的tag
     */
    private String msgTag;

    /**
     * mq的key
     */
    private String msgKey;

    /**
     * 消息体
     */
    private String msgBody;

    /**
     * 0：处理成功；1：处理失败；2：正在处理
     */
    private Integer consumerState;

    /**
     * 处理（消费失败）的次数
     */
    private Integer consumerTimes;

    /**
     * 处理时间
     */
    private LocalDateTime consumerTime;

    /**
     * 备注
     */
    private String remark;


}
